package com.ptkc.core.canal.handler;

import com.alibaba.otter.canal.protocol.CanalEntry;
import com.google.protobuf.InvalidProtocolBufferException;

import java.util.Collection;

/**
 * @author: Mr.Jiao
 * @date: 2018年09月29日
 */
public interface EventHandler {

    void handle(CanalEntry.Entry entry, CanalEntry.RowChange change);

    boolean getSubscribe(String database, String table);

    String getDatabase();

    String getTable();

}
